type google.golang.org/grpc.clientStream
17 uses
google.golang.org/grpc (current package)
stream.go#L354: cs := &clientStream{
stream.go#L439: func (cs *clientStream) newAttemptLocked(isTransparent bool) (*csAttempt, error) {
stream.go#L574: type clientStream struct {
stream.go#L638: cs *clientStream
stream.go#L664: func (cs *clientStream) commitAttemptLocked() {
stream.go#L677: func (cs *clientStream) commitAttempt() {
stream.go#L783: func (cs *clientStream) retryLocked(attempt *csAttempt, lastErr error) error {
stream.go#L806: func (cs *clientStream) Context() context.Context {
stream.go#L816: func (cs *clientStream) withRetry(op func(a *csAttempt) error, onSuccess func()) error {
stream.go#L862: func (cs *clientStream) Header() (metadata.MD, error) {
stream.go#L901: func (cs *clientStream) Trailer() metadata.MD {
stream.go#L916: func (cs *clientStream) replayBufferLocked(attempt *csAttempt) error {
stream.go#L925: func (cs *clientStream) bufferForRetryLocked(sz int, op func(a *csAttempt) error, cleanup func()) {
stream.go#L939: func (cs *clientStream) SendMsg(m any) (err error) {
stream.go#L1010: func (cs *clientStream) RecvMsg(m any) error {
stream.go#L1039: func (cs *clientStream) CloseSend() error {
stream.go#L1069: func (cs *clientStream) finish(err error) {
The pages are generated with Golds v0.8.4. (GOOS=linux GOARCH=amd64)